package com.doit.day01;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

import java.sql.*;
import java.util.HashMap;
import java.util.Locale;

/**
 *  去mysql数据库中查询数据
 *  还要建立一个缓存系统   ==》 hashmap来代替
 *  去mysql数据库中查询数据之前，先去hashmap里面查一下，如果有，直接返回结果，如果没有再去查询mysql数据库
 *  查询完mysql数据库以后，还要在将查询到的数据添加到hashmap中
 */
public class _06_发布和订阅 {
    public static void main(String[] args)  {
        Jedis jedis = new Jedis("linux01", 6379);


        jedis.subscribe(new JedisPubSub() {
            @Override
            public void onMessage(String channel, String message) {
                //处理业务逻辑
                if ("A".equals(channel)){
                    System.out.println("A渠道的消息是："+message);
                }else if ("B".equals(channel)){
                    System.out.println("B渠道的消息是："+message.toUpperCase());
                }else {
                    System.out.println("C渠道的消息是："+message+"ccccccccc");
                }


            }
        },"A","B","C");




    }
}
